cde26788a61a707bc9eea845cf909d75c5c9905f,api/topology/src/test/java/quarks/test/topology/PlumbingTest.java,PlumbingTest,testConcurrentMap,#,317
Before Change
public void testConcurrentMap() throws Exception {
Topology top = newTopology("testConcurrentMap");
Function<Integer,JsonObject> a1 = fakeAnalytic(0, 100, TimeUnit.MILLISECONDS);
Function<Integer,JsonObject> a2 = fakeAnalytic(1, 100, TimeUnit.MILLISECONDS);
Function<Integer,JsonObject> a3 = fakeAnalytic(2, 100, TimeUnit.MILLISECONDS);
Function<Integer,JsonObject> a4 = fakeAnalytic(3, 100, TimeUnit.MILLISECONDS);
After Change
public void testConcurrentMap() throws Exception {
Topology top = newTopology("testConcurrentMap");
int ch = 0;
List<Function<Integer,JsonObject>> mappers = new ArrayList<>();
mappers.add(fakeAnalytic(ch++, 100, TimeUnit.MILLISECONDS));
mappers.add(fakeAnalytic(ch++, 100, TimeUnit.MILLISECONDS));
mappers.add(fakeAnalytic(ch++, 100, TimeUnit.MILLISECONDS));
mappers.add(fakeAnalytic(ch++, 100, TimeUnit.MILLISECONDS));
mappers.add(fakeAnalytic(ch++, 100, TimeUnit.MILLISECONDS));
mappers.add(fakeAnalytic(ch++, 100, TimeUnit.MILLISECONDS));
// a couple much faster just in case something's amiss with queues
mappers.add(fakeAnalytic(ch++, 3, TimeUnit.MILLISECONDS));
mappers.add(fakeAnalytic(ch++, 13, TimeUnit.MILLISECONDS));
Function<List<JsonObject>,Integer> combiner = list -> {